package com.algo.panelmn;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.util.ToolRunner;

public class RunChainJob1 {

	public static void main(String[] args) throws Exception {
		for(int i = 0; i< args.length; i++)
			System.out.println("job1:" + args[i]);
		Configuration conf = new Configuration();
		ToolRunner.run(conf , new TestCookie(), args);
		String[] step2args = new String[3];
		step2args[0] = "-Dmapred.job.queue.name=algo";
		step2args[1] = args[8];
		step2args[2] = args[8] + "/step2";
		ToolRunner.run(conf, new SnsReduce(), step2args);
		String[] step3args = new String[3];
		step3args[0] = "-Dmapred.job.queue.name=algo";
		step3args[1] = step2args[2];
		step3args[2] = args[8] + "/step3";
		int res = ToolRunner.run(conf, new CookieUV(), step3args);
	}
}
